package com.cloud.rou.im.client.msg;

import com.cloud.rou.im.core.base.ResultVO;
import com.cloud.rou.im.core.util.SingletonUtil;
import com.cloud.rou.im.msg.Msg;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * <p></p>
 *
 * @author GaoShuangWen
 */
public class MsgRequestPool {
    private Map<Long, Msg> requestMap;

    private MsgRequestPool() {
        this.requestMap = new ConcurrentHashMap<>();
    }

    public static MsgRequestPool getInstance() {
        return SingletonUtil.get(MsgRequestPool.class);
    }

    public void add(Msg msg) {
        requestMap.put(msg.getMsgId(), msg);
    }

    public Msg get(Long id) {
        return requestMap.get(id);
    }
}
